package com.xiaoke;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.io.FileWriter;
import java.io.IOException;

import com.alibaba.fastjson.JSON;

public class Cleaner {

	public static void main(String[] args) throws IOException {
		// TODO 自动生成的方法存根
		BufferedReader br = new BufferedReader(
				new FileReader("C:\\Users\\Administrator\\Desktop\\Hadoop部署实践\\Film.json"));
		FileWriter sw = new FileWriter(new File("Film.csv"));
		// MovieInfo 类可以参考实验1
		MovieInfo m = null;
		String line;
		while ((line = br.readLine()) != null) {
			// Fastjson 把每行的json 字符串转换为对象。
			m = JSON.parseObject(line, MovieInfo.class);
			if (m.getActor().indexOf("浅野忠信") != -1) {
				// Film_page 作为电影ID
				String mid = m.getFilm_page();
				// 取出演员的列表
				String[] actors = m.getActor().split(",");
				for (String ac : actors) {
					// 把电影数据写入csv文件。csv 表头为 ID,电影名称,评分,演员
					try {
						sw.append(mid + "," + m.getTitle() + "," + ac + "," + m.getStar() + "\n");
						sw.flush();
					} catch (IOException e) {
						// TODO 自动生成的 catch 块
						e.printStackTrace();
					}
				}
			}
		}
	}

}
